package com.itany.corejava.day18;


import java.net.ServerSocket;
import java.net.Socket;
import java.util.Set;

public class ChatRoomServer {

    private ServerSocket ss;

    private Set<Socket> allSockets;

    public ChatRoomServer() {
        //启动服务
        //创建allSockets对象
    }

    public void startService(){
        while(true){
            Socket s=null;
            try{

                s=ss.accept();

                //s放入set集合中

                //启动线程

            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }

    class ChatRoomServerThread extends Thread{
        private Socket s;

        public ChatRoomServerThread(Socket s) {
            this.s = s;
        }

        @Override
        public void run() {
            //不停的从s中获得数据
            //判断是什么消息
            //聊天消息或抖动消息
                //将消息发送给所有客户端，聊天消息加上时间

            //进入消息或退出消息
                //如果是退出消息
                    //将Set集合中的对应Socket删除
                //将所有的用户名发送给所有客户端让客户端更新用户列表

        }
    }

    public static void main(String[] args) {
        new ChatRoomServer().startService();
    }
}
